# -*- coding: utf-8 -*-
# @Time:    2025-04-25 17:12
# @Author:  simon
# @Email:   yonglonggeng@163.com
# @WeChat:  ddgetget
# @File:    demo.py
# @Project: dev-tools
# @Package: 
# @Ref:


from airflow import DAG
from airflow.operators.python import PythonOperator
from datetime import datetime
import os

# 定义DAG
with DAG(
    'os_sb_kg',
    start_date=datetime(2025, 4, 25),
    schedule_interval=None,
) as dag:

    def print_env_vars():
        for key, value in os.environ.items():
            print(f"{key}: {value}")

    # 创建任务
    print_env_task = PythonOperator(
        task_id='os_sb_kg_answer',
        python_callable=print_env_vars,
    )

    # 设置任务依赖
    print_env_task